package com.gzsxy.esjy.bus.subscrib;


import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @description: 默认订阅定义
 * 自定义通道名
 */
public interface DefaultStream {

    public final static String DEFAULT_TN = "default-in";
    public final static String DEFAULT_IN_BROADCAST = "default-in-broadcast";

    public final static String HEADER_NAME = "vman";

    /**
     * @description: 广播
     */
    @Input(DEFAULT_IN_BROADCAST)
    SubscribableChannel broadcast();

    /**
     * @description: 单播
     */
    @Input(DEFAULT_TN)
    SubscribableChannel aim();

}
